ElastiCacheのイベント通知をLambdaを使ってフィルタしてみた

五十嵐直樹

2020.04.14

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

ｺﾝﾆﾁﾊ後藤です。

ElastiCacheにはイベントログをSNS経由で通知することが出来る機能があることご存じですか？この機能を利用することで、フェイルオーバや再起動が発生した場合もメール等で通知を受け取ることが出来ます。

しかし、このSNS通知はRDSのイベントサブスクリプションとは違い、全てのイベントログを通知します。そのため、毎日取得しているスナップショット取得のログ等も通知されてしまいます。

そこで、今回はLambdaを使用してイベントログをフィルタし、特定のイベントログのみ通知してみました。

構成

SNSトピック作成

構成図に記載あるように、今回はトピックを2つ用意します。 (1) ElastiCacheからイベントログを受け取り、Lambdaに送信するSNSトピック (2) Lambdaから特定イベントログのみ受け取り、メールを送信するSNSトピック

ElastiCacheのSNS通知を設定

↑で作成したSNSトピック(1)をElastiCacheのSNS通知に設定します。

Lambdaを設定

今回はPython3.8でLambdaを実行しています。

import boto3
import json
import os

sns = boto3.client('sns')

def lambda_handler(event, context):
message = event['Records'][0]['Sns']['Message']
if "FailoverComplete" in message:
print("send mail")
response = sns.publish(
TopicArn = os.environ['sns_topic'],
Message = message,
Subject = os.environ['subject']
)
else:
print("not send mail")
print(message)

今回はフェイルオーバ完了を知らせる[FailoverComplete]が発生した場合、メールを送信するように設定しました。処理を分かり易くするため、メール送信の処理が入った場合 send mail , 入らなかった場合 not send mail とCloudWatchLogsに出力するようにしています。

ElastiCacheのイベントログについては、以下ドキュメントをご参照ください。 ElastiCacheドキュメントイベント通知とAmazon SNS

Lambdaの環境変数でメッセージ送信先のSNSトピック名とメール件名を設定しています。